package com.guo.core.framework.observable;

/**
 * 业务观察者
 * @param <T> 消费数据
 */
public interface BizObserver<T> {

    void consume(T data) throws InterruptedException;

}
